package cn.wolfcode.shop.message;

import javax.jms.Destination;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jms.core.JmsTemplate;
import org.springframework.stereotype.Component;

/**
 * 消息生成类
 * @author stonenic
 *
 */
@Component
public class CreateOrderProducer {

	// 专门用来发消息的对象
	@Autowired
	private JmsTemplate jmsTemplate;

	// 使用方法名来区分多个不同的Destination
	@Autowired
	private Destination createOrderQueue;
//	@Autowired
//	private Destination createOrderTopic;

	/**
	 * 发送消息的方法
	 * 发送的时候需要:消息目的地和消息内容
	 * @param content
	 */
	public void sendMessage(String content) {
		//		ActiveMQQueue activeMQQueue = new ActiveMQQueue("createOrderQueue");// 每次调用都要new一个对象,耗费内存,也交给spring容器管理
		// 将消息转好成message对象发送出去
		jmsTemplate.convertAndSend(createOrderQueue,content);
	}
//	public void sendMessageByTopic(String content) {
//		//		ActiveMQQueue activeMQQueue = new ActiveMQQueue("createOrderQueue");// 每次调用都要new一个对象,耗费内存,也交给spring容器管理
//		// 将消息转好成message对象发送出去
//		jmsTemplate.convertAndSend(createOrderTopic,content);
//	}

}
